//package com.youzan.cloud.component.biz.member.mq;
//
//import com.youzan.cloud.boot.autoconfigure.mq.MQListener;
//import com.youzan.cloud.mq.Message;
//import org.springframework.stereotype.Component;
//
///**
// * @author tangsen233
// * @version 1.0
// * @description: TODO
// * @date 2021/9/23 16:06
// */
//@Component
//public class ConsumerMemberCreateAfter {
//
//    @MQListener(topic = "member_create_before", consumerGroup = "member_create")
//    public void consume(Message message) {
//        // doSomething
//        // 消费失败（throw exception）消息会重新推送
//    }
//}